type google.golang.org/grpc/internal/transport.loopyWriter

25 uses

	google.golang.org/grpc/internal/transport (current package)
		controlbuf.go#L470: type loopyWriter struct {
		controlbuf.go#L494: func newLoopyWriter(s side, fr *framer, cbuf *controlBuffer, bdpEst *bdpEstimator) *loopyWriter {
		controlbuf.go#L496: 	l := &loopyWriter{
		controlbuf.go#L529: func (l *loopyWriter) run() (err error) {
		controlbuf.go#L580: func (l *loopyWriter) outgoingWindowUpdateHandler(w *outgoingWindowUpdate) error {
		controlbuf.go#L584: func (l *loopyWriter) incomingWindowUpdateHandler(w *incomingWindowUpdate) error {
		controlbuf.go#L602: func (l *loopyWriter) outgoingSettingsHandler(s *outgoingSettings) error {
		controlbuf.go#L606: func (l *loopyWriter) incomingSettingsHandler(s *incomingSettings) error {
		controlbuf.go#L613: func (l *loopyWriter) registerStreamHandler(h *registerStream) error {
		controlbuf.go#L624: func (l *loopyWriter) headerHandler(h *headerFrame) error {
		controlbuf.go#L659: func (l *loopyWriter) originateStream(str *outStream, hdr *headerFrame) error {
		controlbuf.go#L677: func (l *loopyWriter) writeHeader(streamID uint32, endStream bool, hf []hpack.HeaderField, onWrite func()) error {
		controlbuf.go#L723: func (l *loopyWriter) preprocessData(df *dataFrame) error {
		controlbuf.go#L738: func (l *loopyWriter) pingHandler(p *ping) error {
		controlbuf.go#L746: func (l *loopyWriter) outFlowControlSizeRequestHandler(o *outFlowControlSizeRequest) error {
		controlbuf.go#L751: func (l *loopyWriter) cleanupStreamHandler(c *cleanupStream) error {
		controlbuf.go#L771: func (l *loopyWriter) earlyAbortStreamHandler(eas *earlyAbortStream) error {
		controlbuf.go#L797: func (l *loopyWriter) incomingGoAwayHandler(*incomingGoAway) error {
		controlbuf.go#L807: func (l *loopyWriter) goAwayHandler(g *goAway) error {
		controlbuf.go#L819: func (l *loopyWriter) closeConnectionHandler() error {
		controlbuf.go#L826: func (l *loopyWriter) handle(i interface{}) error {
		controlbuf.go#L861: func (l *loopyWriter) applySettings(ss []http2.Setting) error {
		controlbuf.go#L886: func (l *loopyWriter) processData() (bool, error) {
		http2_client.go#L73: 	loopy      *loopyWriter
		http2_server.go#L73: 	loopy       *loopyWriter